package cn.hy.dataSync.config;

import cn.hy.dataSync.element.Record;


public interface RecordSender {
    /**
     * 创建单条记录
     */
    Record createRecord();

    /**
     * 发送到写入器
     */
    void sendToWriter(Record record);

    /**
     * 批量刷新
     */
    void flush();

    /**
     * 终止
     */
    void terminate();

    /**
     * 关闭
     */
    void shutdown();
}
